package jtcl.tech.kafka.listener;

import jtcl.tech.kafka.dto.KafkaConfigDTO;

/**
 * <p>kafka工厂初始化时调用，用于修改kafka配置</p>
 *
 * @author shijinting
 * @since 2021-08-27 15:49
 */
public interface KafkaInitListener {

    /**
     * <p>更新kafka配置</p>
     *
     * @param config
     * @return cec.ics.cloud.queue.kafka.dto.KafkaConfigDTO
     * @author 施锦庭
     * @since 2021-08-27 15:51
     **/
    KafkaConfigDTO updateConfig(KafkaConfigDTO config);
}
